package hello

import org.apache.spark.{SparkConf, SparkContext}
object Test3 {
  def main(array: Array[String]):Unit={
    val sc= new SparkContext(new SparkConf()
    .setAppName("UionExample")
      .setMaster("local"))

    val rdd1 = sc.parallelize(List(('a',1),('b',2),('e',3)))
    val rdd2 = sc.parallelize(List(('a',1),('b',4),('c',5)))

    rdd1.filter(_._2>1).collect().foreach(println)
    rdd1.filter(x=>x._2>1).collect().foreach(println)

    rdd1.union(rdd2).collect().foreach(println)

    sc.stop()
  }

}
